#[derive(uniffi::Record)]
pub struct FfiMessageWithReactions {
    pub message: FfiMessage,
    pub reactions: Vec<FfiMessage>,
}

pub async fn find_messages_with_reactions(
        &self,
        opts: FfiListMessagesOptions,
    ) -> Result<Vec<FfiMessageWithReactions>, GenericError> {
        let delivery_status = opts.delivery_status.map(|status| status.into());
        let direction = opts.direction.map(|dir| dir.into());
        let kind = match self.conversation_type()? {
            FfiConversationType::Group => None,
            FfiConversationType::Dm => Some(GroupMessageKind::Application),
            FfiConversationType::Sync => None,
        };

        let messages: Vec<FfiMessageWithReactions> = self
            .inner
            .find_messages_with_reactions(
                &MsgQueryArgs::default()
                    .maybe_sent_before_ns(opts.sent_before_ns)
                    .maybe_sent_after_ns(opts.sent_after_ns)
                    .maybe_kind(kind)
                    .maybe_delivery_status(delivery_status)
                    .maybe_limit(opts.limit)
                    .maybe_direction(direction),
            )?
            .into_iter()
            .map(|msg| msg.into())
            .collect();
        Ok(messages)
    }